
/**
 * 合并chunk
 */
const mergeChunks = () => {

}

/**
 * 数据从可读流 流向  可写流
 * @param {ReadableStream} rs 可读流
 * @param {WritableStream} ws 可写流
 * @returns 返回一个Promise, 当流结束的时候， Promise 会被resolve
 */
const pipeStream = (rs, ws) => {
  return new Promise((resolve, reject) => {
    rs.pipe(ws).on('finish', resolve).on('error', reject)
  })
}


module.exports = {
  mergeChunks,
  pipeStream
}